package storm;

import org.apache.storm.topology.BasicOutputCollector;
import org.apache.storm.topology.OutputFieldsDeclarer;
import org.apache.storm.topology.base.BaseBasicBolt;
import org.apache.storm.tuple.Tuple;

public class PrintBolt extends BaseBasicBolt {  
	  
    public void execute(Tuple tuple, BasicOutputCollector collector) {  
        String rec = tuple.getString(0);  
        System.err.println("String recieved: " + rec);  
    }  
  
    public void declareOutputFields(OutputFieldsDeclarer declarer) {  
        // do nothing  
    }  
  
}  